954745a5d7cdbc625ca9bf7a2662fabd187cae5c,test/io/tetrapod/raft/RaftEngineTester.java,RaftEngineTester,sendAppendEntries,#number#number#number#number#number#Entry[]#number#AppendEntriesResponseHandler#,210
Before Change
final Entry<TestStateMachine>[] entries, final long leaderCommit, final AppendEntriesResponseHandler handler) {
final RaftEngine<TestStateMachine> r = rafts.get(peerId);
if (r != null) {
executor.schedule(new Runnable() {
public void run() {
try {
r.handleAppendEntriesRequest(term, leaderId, prevLogIndex, prevLogTerm, entries, leaderCommit, handler);
} catch (Throwable t) {
logger.error(t.getMessage(), t);
}
}
}, randomDelay(), TimeUnit.MILLISECONDS);
}
}
After Change
final Entry<TestStateMachine>[] entries, final long leaderCommit, final AppendEntriesResponseHandler handler) {
final RaftEngine<TestStateMachine> r = rafts.get(peerId);
if (r != null) {
executor.schedule(() -> {
try {
r.handleAppendEntriesRequest(term, leaderId, prevLogIndex, prevLogTerm, entries, leaderCommit, handler);
} catch (Throwable t) {
logger.error(t.getMessage(), t);
}
}, randomDelay(), TimeUnit.MILLISECONDS);
}
}